package com.imchenio.utils.parallel.runnable;

import java.util.concurrent.BlockingQueue;

public abstract class ChannelRunnable<T> implements Runnable {

    protected BlockingQueue<T> blockingQueue;

    public void setBlockingQueue(BlockingQueue<T> blockingQueue) {
        this.blockingQueue = blockingQueue;
    }
}
